package org.dromara.system.controller.system;

import cn.dev33.satoken.secure.BCrypt;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.io.FileUtil;
import lombok.RequiredArgsConstructor;
import org.dromara.common.core.domain.R;
import org.dromara.common.core.utils.StringUtils;
import org.dromara.common.core.utils.file.MimeTypeUtils;
import org.dromara.common.encrypt.annotation.ApiEncrypt;
import org.dromara.common.idempotent.annotation.RepeatSubmit;
import org.dromara.common.log.annotation.Log;
import org.dromara.common.log.enums.BusinessType;
import org.dromara.common.satoken.utils.LoginHelper;
import org.dromara.common.web.core.BaseController;
import org.dromara.system.domain.bo.SysUserBo;
import org.dromara.system.domain.bo.SysUserPasswordBo;
import org.dromara.system.domain.bo.SysUserProfileBo;
import org.dromara.system.domain.vo.AvatarVo;
import org.dromara.system.domain.vo.ProfileVo;
import org.dromara.system.domain.vo.SysOssVo;
import org.dromara.system.domain.vo.SysUserVo;
import org.dromara.system.service.ISysOssService;
import org.dromara.system.service.ISysUserService;
import org.springframework.http.MediaType;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

import java.util.Arrays;


/**
 * @Author 刘武贵
 * @Date 2024/8/15 22:00
 * @Description 功能描述：个人信息 业务处理
 */
@Validated
@RequiredArgsConstructor
@RestController
@RequestMapping("/system/user/profile")
public class SysProfileController extends BaseController {

    /**
     * 用户 业务层
     */
    private final ISysUserService userService;

    /**
     * 文件上传 服务层
     */
    private final ISysOssService ossService;

    /**
     * 个人信息
     *
     * @return 包含用户个人资料信息的响应对象
     */
    @GetMapping
    public R<ProfileVo> profile() {
        SysUserVo user = userService.selectUserById(LoginHelper.getUserId());
        // 初始化个人资料对象
        ProfileVo profileVo = new ProfileVo();
        // 设置用户信息
        profileVo.setUser(user);
        // 设置用户的角色组信息
        profileVo.setRoleGroup(userService.selectUserRoleGroup(user.getUserId()));
        // 设置用户的岗位组信息
        profileVo.setPostGroup(userService.selectUserPostGroup(user.getUserId()));
        return R.ok(profileVo);
    }

    /**
     * 修改用户信息
     *
     * @param profile 经过验证的用户个人资料对象
     * @return 返回一个泛型为Void的R对象，包含操作结果的状态和消息
     */
    @RepeatSubmit
    @Log(title = "个人信息", businessType = BusinessType.UPDATE)
    @PutMapping
    public R<Void> updateProfile(@Validated @RequestBody SysUserProfileBo profile) {
        // 将用户个人资料转换为系统用户对象
        SysUserBo user = BeanUtil.toBean(profile, SysUserBo.class);
        // 设置用户的ID
        user.setUserId(LoginHelper.getUserId());
        // 获取当前用户名
        String username = LoginHelper.getUsername();

        // 检查电话号码是否唯一
        if (StringUtils.isNotEmpty(user.getPhonenumber()) && !userService.checkPhoneUnique(user)) {
            return R.fail("修改用户'" + username + "'失败，手机号码已存在");
        }
        // 检查电子邮件是否唯一
        if (StringUtils.isNotEmpty(user.getEmail()) && !userService.checkEmailUnique(user)) {
            return R.fail("修改用户'" + username + "'失败，邮箱账号已存在");
        }

        // 更新用户资料，如果影响行数大于0，表示成功
        if (userService.updateUserProfile(user) > 0) {
            return R.ok();
        }
        // 更新失败，返回异常失败消息
        return R.fail("修改个人信息异常，请联系管理员");
    }

    /**
     * 重置密码
     *
     * @param bo 新旧密码
     * @return R<Void> 返回一个结果对象，其中不包含数据（Void表示空）
     *         可能的结果状态包括：
     *         - 成功（R.ok()）
     *         - 旧密码错误（"修改密码失败，旧密码错误"）
     *         - 新密码不能与旧密码相同（"新密码不能与旧密码相同"）
     *         - 修改密码异常（"修改密码异常，请联系管理员"）
     */
    @RepeatSubmit
    @ApiEncrypt
    @Log(title = "个人信息", businessType = BusinessType.UPDATE)
    @PutMapping("/updatePwd")
    public R<Void> updatePwd(@Validated @RequestBody SysUserPasswordBo bo) {
        // 通过登录用户ID查询用户信息
        SysUserVo user = userService.selectUserById(LoginHelper.getUserId());
        // 获取当前用户的密码
        String password = user.getPassword();

        // 验证旧密码是否正确
        if (!BCrypt.checkpw(bo.getOldPassword(), password)) {
            return R.fail("修改密码失败，旧密码错误");
        }

        // 确保新密码不与旧密码相同
        if (BCrypt.checkpw(bo.getNewPassword(), password)) {
            return R.fail("新密码不能与旧密码相同");
        }

        // 如果更新成功（影响行数大于0），则返回成功响应
        if (userService.resetUserPwd(user.getUserId(), BCrypt.hashpw(bo.getNewPassword())) > 0) {
            return R.ok();
        }
        return R.fail("修改密码异常，请联系管理员");
    }

    /**
     * 头像上传
     *
     * @param avatarfile 用户头像
     * @return 返回包含头像URL的AvatarVo对象，或者失败消息
     */
    @RepeatSubmit
    @Log(title = "用户头像", businessType = BusinessType.UPDATE)
    @PostMapping(value = "/avatar", consumes = MediaType.MULTIPART_FORM_DATA_VALUE)
    public R<AvatarVo> avatar(@RequestPart("avatarfile") MultipartFile avatarfile) {
        if (!avatarfile.isEmpty()) {
            // 获取文件扩展名
            String extension = FileUtil.extName(avatarfile.getOriginalFilename());
            // 检查文件是否为图片格式
            if (!StringUtils.equalsAnyIgnoreCase(extension, MimeTypeUtils.IMAGE_EXTENSION)) {
                return R.fail("文件格式不正确，请上传" + Arrays.toString(MimeTypeUtils.IMAGE_EXTENSION) + "格式");
            }
            // 将文件上传到OSS服务并获取上传信息
            SysOssVo oss = ossService.upload(avatarfile);
            String avatar = oss.getUrl();
            // 更新用户头像的数据库记录
            if (userService.updateUserAvatar(LoginHelper.getUserId(), oss.getOssId())) {
                AvatarVo avatarVo = new AvatarVo();
                avatarVo.setImgUrl(avatar);
                return R.ok(avatarVo);
            }
        }
        return R.fail("上传图片异常，请联系管理员");
    }
}
